package com.wlh.demo02;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * @author WuLiangHang
 */
public class ThreadPoolDemo {
    public static void main(String[] args) {
        //创建线程池对象
        //包含两个线程对象
        ExecutorService service = Executors.newFixedThreadPool(2);
        //创建Runnable实例对象
        MyRunnable r = new MyRunnable();
        //自己创建线程的方式
//        Thread t = new Thread(r);
//        t.start();
        //从线程池中获取线程对象 然后调用MyRunnable中的run()
        service.submit(r);
        service.submit(r);
        service.submit(r);
        //submit方法调用结束后，程序不会终止 因为线程池控制了线程的关闭
        //将使用完的线程又归还到线程池中
        service.submit(r);
        service.submit(r);
        //该方法 关闭线程池
        service.shutdown();
    }
}
